//package com.example.demo.utils;
//
//import java.util.Date;
//import java.util.UUID;
//
//import org.slf4j.Logger;
//import org.slf4j.LoggerFactory;
//import org.springframework.beans.factory.annotation.Autowired;
//import org.springframework.kafka.core.KafkaTemplate;
//import org.springframework.stereotype.Component;
//
//import com.example.demo.entity.TSysRole;
//import com.google.gson.Gson;
//import com.google.gson.GsonBuilder;
//
//@Component
//public class KfkaProducer {
//	
//	private static Logger logger = LoggerFactory.getLogger(KfkaProducer.class);
//	
//	@Autowired
//	private KafkaTemplate<String, String> kafkaTemplate;
//	
//	private Gson gson = new GsonBuilder().create();
//	
//	//发送消息方法
//    public void send() {
//    	for(int i=0;i<5;i++){
//    		TSysRole message = new TSysRole();
//            message.setId(System.currentTimeMillis());
//            message.setName(UUID.randomUUID().toString()+ "---" +i);
//            message.setCreateTime(new Date());
//            logger.info("发送消息 ----->>>>>  message = {}", gson.toJson(message));
//            kafkaTemplate.send("hello", gson.toJson(message));
//    	}
//    }
//
//	
//}